/**
 * 模型基类
 */
const mysql = require('mysql')
module.exports = class Mysql {
    constructor() {
        this.connection = mysql.createConnection({
            host:'127.0.0.1',
            user:'root',
            password:'ok',
            database:'hot'
        })
    }
    /*
    通用查询
    */
    query(sql,params=[]){
        return new Promise((resolve,reject)=>{
            this.connection.query(sql,params,(err,results)=>{
                err?reject(err):resolve(results)
            })
        })
    }
     /**
     * 查询操作
     * @param {*} sql 
     * @param {*} params 
     */
    async select(sql,params=[]){
        return await this.query(sql,params)
    }

    async insert(sql,params=[]){
        let results=await this.query(sql,params)
        console.log(results)
        return {rows:results.affectedRows,insertId:results.insertId}
    }
    async delete(sql,params=[]){
        let results= await this.query(sql,params)
        return {rows:results.affectedRows}
    }
    /**
     * 更新
     * @param {*} sql 
     * @param {*} params 
     */
    async update(sql,params=[]){
      return this.delete(sql,params)
    }
}